package com.ds.infrastructure.audit.client.track;

import com.ds.infrastructure.audit.common.entity.KbaBehaviorWrapper;
import org.apache.kafka.common.serialization.Serializer;

/**
 * 作用：
 *
 * @author WeiShaoying
 * @date 2020/8/24
 */
public class KbaBehaviorWrapperEncoder implements Serializer<KbaBehaviorWrapper> {

    @Override
    public byte[] serialize(String s, KbaBehaviorWrapper wrapper) {
        return wrapper.toBytes();
    }

}
